import os
import sys

# 初始化导包路径, 需要用到的项目的根路径都加入到 sys.path
# 导包时, 从用各自项目的根路径 下一级开始写路径 , 就是不用写根路径目录名
BASE_DIR = os.path.dirname(__file__)
sys.path.insert(0, BASE_DIR)  # celery 项目的根目录
sys.path.insert(0, os.path.join(BASE_DIR, '../meiduo_mall'))  # meiduo_mall 项目的根目录
print(sys.path)

from celery import Celery

# 工作看板, 发布任务和接收处理任务, 异步执行的信息
# app = Celery('meiduo_celery', broker='redis://127.0.0.1:6379/14', backend='redis://127.0.0.1:6379/15')
celery_app = Celery('meiduo_celery')

celery_app.config_from_object('config')

celery_app.autodiscover_tasks(['tasks.calc', 'tasks.sms'])

# @celery_app.task()
# def add(x, y):
#     return x, y

# 启动celery worker进程, 即创建一个消费者, 来处理任务
# 进入celery_tasks目录执行命令:
# celery -A main worker -l info

# 参数说明:
# -A main 指入口模块: main
# worker 指启动一个消费者/工作者
# -l info  指输出日志
